package com.heima.kafka.boot.listener;

import com.alibaba.fastjson.JSON;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

import java.util.Map;

@Component
public class ConsumerListener {
    /**
     * 监听
     * @kafjalistener(topics = )
     * topics属性表示监听的具体的主题,返回值字符串数组类型,也就意味着可以监听多组的主题
     *
     * 注意:监听的方法中的参数是作为获取消息的方式
     */
    @KafkaListener(topics = "boot-topic")
    public void getMessage(String message){
        //System.out.println("消息内容:"+message);

        //转换类型格式
        Map map = JSON.parseObject(message, Map.class);
        System.out.println(map);
    }
}
